package org.tksj.bim.common.mq;

/**
 * @author luyongqiang
 */
public interface MqConsumer<T> {

    void consume(String topic, ConsumerHandler<T> handler);

}